//package com.per.mybootall.kafka;
//
//import org.apache.kafka.clients.producer.KafkaProducer;
//import org.apache.kafka.clients.producer.ProducerRecord;
//import org.apache.kafka.common.serialization.StringSerializer;
//
//import java.util.Properties;
//
//public class Product {
//    public static void main(String[] args) {
//        //配置信息
//        Properties props = new Properties();
//        //kafka服务器地址
//        props.put("bootstrap.servers", "150.158.98.73:9092");
//        //设置数据key和value的序列化处理类
//        props.put("key.serializer", StringSerializer.class);
//        props.put("value.serializer", StringSerializer.class);
//        /*  创建生产者实例  Topic （名字）       PartitionID ( 可选)           Key[( 可选 )          Value
//
//            <1> 若指定Partition ID,则PR被发送至指定Partition
//            <2> 若未指定Partition ID,但指定了Key, PR会按照hasy(key)发送至对应   Partition
//            <3> 若既未指定Partition ID也没指定Key，PR会按照round-robin模式发送到每个Partition
//            <4> 若同时指定了Partition ID和Key, PR只会发送到指定的Partition (Key不起作用，代码逻辑决定)    */
//
//        KafkaProducer<String,String> producer = new KafkaProducer<>(props);
//        for(int i=0;i<120;i++){
//            ProducerRecord record = new ProducerRecord<String, String>("myKafkaTopic", "userName", String.valueOf(i));
//            producer.send(record);
//        }
//
//        //发送记录
//
//        producer.close();
//        System.out.println("发送完成，连接关闭==》");
//    }
//}
